f113d79451ba88c487358861cc3e20aac3d19257,flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java,MiniClusterITCase,runJobWithMultipleRpcServices,#,53

Before Change


		cfg.setUseRpcServicePerComponent();

		MiniCluster miniCluster = new MiniCluster(cfg);
		executeJob(miniCluster);
	}

	@Test

After Change



		MiniCluster miniCluster = new MiniCluster(cfg);
		try {
			miniCluster.start();
			executeJob(miniCluster);
		}
		finally {
			miniCluster.shutdown();